//package tech.powerjob.samples.workflow;
//
//import com.alibaba.fastjson.JSON;
//import lombok.extern.slf4j.Slf4j;
//import tech.powerjob.worker.core.processor.ProcessResult;
//import tech.powerjob.worker.core.processor.TaskContext;
//import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
//import tech.powerjob.worker.log.OmsLogger;
//import org.springframework.stereotype.Component;
//
//import java.util.Map;
//
///**
// * 工作流测试
// *
// * @author tjq
// * @since 2020/6/2
// */
//@Component
//@Slf4j
//public class WorkflowStandaloneProcessor implements BasicProcessor {
//
//    @Override
//    public ProcessResult process(TaskContext context) throws Exception {
//        OmsLogger logger = context.getOmsLogger();
//        logger.info("current jobParams: {}", context.getJobParams());
//        logger.info("current context: {}", context.getWorkflowContext());
//        log.info("jobParams:{}", context.getJobParams());
//        log.info("currentContext:{}", JSON.toJSONString(context));
//
//        // 尝试获取上游任务
//        Map<String, String> workflowContext = context.getWorkflowContext().fetchWorkflowContext();
//        log.info("工作流上下文数据:{}", workflowContext);
//        return new ProcessResult(true, context.getJobId() + " process successfully.");
//    }
//}
